package com.boat.starter.pulsar.constant;

/**
 * Description: 常量
 *
 * @author: zuomin (myleszelic@outlook.com)
 * @date: 2021/07/12-09:12
 */
public final class MQConstant {

	public static final String VERSION = "boat_1.3";
	
    public static final String PREFIX = "boat.mq";
    
    public static final String TAGS = "TAGS";

    public static class MqType {
        public static final String PULSAR = "pulsar";
        public static final String ROCKET_MQ = "rocketmq";
    }

    public static class Header {
    	//id和timestamp底层代码已生成，且不可修改
        public static final String ID = "id";
        //内容为时间戳long型
        public static final String TIMESTAMP = "timestamp";
        
        //自定义头
        public static final String CREATE_TIME = "createTime";
        public static final String PRODUCER_VERSION = "prodVersion";
        public static final String PRODUCER_APP_NAME = "prodAppName";
        public static final String PRODUCER_IP = "prodIp";
        public static final String TAGS = "tags";
    }
}
